package cn._2dland.websocket.io;

import java.io.FilterInputStream;
import java.io.IOException;
import java.io.InputStream;

import cn._2dland.websocket.model.message.Message;

/**
 * 报文输入流，封装了对报文的读取
 * 
 * @author deadblue
 */
public abstract class MessageInputStream extends FilterInputStream {

	protected MessageInputStream(InputStream in) {
		super(in);
	}

	/**
	 * 从输入流中读取一个报文
	 */
	public abstract Message readMessage() throws IOException;
}
